#练习代码
import queue
import threading
# 定义一个处理函数，用于从队列中获取数据并进行处理
def worker(q):
    while True:
        item = q.get()
        if item is None:
            break
        print("Processing item:", item)
# 创建一个队列对象
q = queue.Queue()
# 启动多个工作线程
for i in range(5):
    t = threading.Thread(target=worker, args=(q,))
    t.start()
# 向队列中添加数据
for item in range(10):
    q.put(item)
# 等待所有工作线程完成
for i in range(5):
    q.put(None)
# 输出结果
print("All items processed")

